#!/bin/sh
###################################################
###   基础表:      党员党费缴费明细表
###   维护人:      shilipeng
###   数据源:
###   问题:

###  导入方式:      全量导入
###  运行频率:      每月一次
###################################################
cd `dirname $0`
source ../../config.sh
exec_dir party_fee_info

HIVE_DB=model
HIVE_TABLE=party_fee_info
TARGET_TABLE=party_fee_info

function create_table(){

        hadoop fs -rm -r ${BASE_HIVE_DIR}/${HIVE_DB}/${HIVE_TABLE} || :

        hive -e "DROP TABLE IF EXISTS ${HIVE_DB}.${HIVE_TABLE};"

        hive -e "CREATE TABLE IF NOT EXISTS ${HIVE_DB}.${HIVE_TABLE}(
              name      STRING    COMMENT '党员名称',
              need_fee      STRING    COMMENT '应缴党费额',
              actual_fee      STRING    COMMENT '实缴党费',
              status      STRING    COMMENT '状态:0未缴纳 1已经缴纳',
              need_year      STRING    COMMENT '缴费年（应缴费年）',
              actual_year      STRING    COMMENT '缴费年月（实际缴费）',
              semester_year      STRING    COMMENT '学年'
               )
        LOCATION '${BASE_HIVE_DIR}/${HIVE_DB}/${HIVE_TABLE}'"

        fn_log "党员党费缴费明细表--'${HIVE_DB}.${HIVE_TABLE}'"
}

function import_table(){

        hive -e "
             INSERT OVERWRITE TABLE ${HIVE_DB}.${HIVE_TABLE}
        "
        fn_log " 导入数据--党员党费缴费明细表:${HIVE_DB}.${HIVE_TABLE}"

}


init_exit
create_table
import_table
finish